package com.raymond.queue.client.handler;


import com.raymond.queue.client.QueueClient;
import com.raymond.queue.common.msg.response.ConsumptionMsgResponse;
import io.netty.channel.ChannelHandlerContext;

/**
 * 消费消息响应处理
 *
 * @author :  raymond
 * @version :  V1.0
 * @date :  2021-07-14 17:50
 */
public class ConsumptionMsgResponseHandler extends BaseBusinessHandler<ConsumptionMsgResponse> {

    public ConsumptionMsgResponseHandler(QueueClient queueClient) {
        super(ConsumptionMsgResponse.class, queueClient);
    }

    @Override
    protected void channelRead(ChannelHandlerContext ctx, ConsumptionMsgResponse msg) throws Exception {
        responseNotice(msg);
    }


}
